package com.kloooong.top.push;

import com.alibaba.fastjson.JSONObject;
import com.dingteam.push.api.channel.MarketOrderChannel;
import com.dingteam.push.api.channel.MarketOrderInput;
import com.dingteam.push.api.message.MarketOrderMessage;
import com.kloooong.top.channel.UserVipInput;
import com.kloooong.top.message.UserVipMember;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(MarketOrderChannel.class)
public class BizId17 {


    @StreamListener(target = MarketOrderInput.INPUT ,condition = "headers['syncAction']=='market_order' and headers['suiteId']=='"+Contain.stuidId666+"'")
    public void suid666(MarketOrderMessage orgOrder) {
        System.out.println("666 17 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgOrder));
    }


    @StreamListener(target = MarketOrderInput.INPUT ,condition = "headers['syncAction']=='market_order' and headers['suiteId']=='"+Contain.stuidId777+"'")
    public void suid777(MarketOrderMessage orgOrder) {
        System.out.println("777 17 data is coming 。。。");
        System.out.println("data："+ JSONObject.toJSONString(orgOrder));
    }



}
